ExecutorService threadPool = Executors.newFixedThreadPool(5);

        var transport = HttpClientSseClientTransport.builder("xxxxxx")
                .sseEndpoint("xxxxxx")
                .build();
        var asyncClient = McpClient.async(transport).build();

        asyncClient.initialize().block(Duration.ofSeconds(10));
        Map<String, Object> arguments = new HashMap<>();
        McpSchema.CallToolRequest request = new McpSchema.CallToolRequest("xxxxxx", arguments);

        Mono<McpSchema.CallToolResult> mono1 = asyncClient.callTool(request)
                .timeout(Duration.ofSeconds(30))
                .doOnSuccess(result -> {
                    System.out.println("--> get success response" + result);
                })
                .doOnError(error -> {
                    System.out.println("failed");
                    System.out.println(error.getMessage());
                });

        Mono<McpSchema.CallToolResult> mono2 = asyncClient.callTool(request)
                .timeout(Duration.ofSeconds(30))
                .doOnSuccess(result -> {
                    System.out.println("--> get success response" + result);
                })
                .doOnError(error -> {
                    System.out.println("failed");
                    System.out.println(error.getMessage());
                });

        Mono<McpSchema.CallToolResult> mono3 = asyncClient.callTool(request)
                .timeout(Duration.ofSeconds(30))
                .doOnSuccess(result -> {
                    System.out.println("--> get success response" + result);
                })
                .doOnError(error -> {
                    System.out.println("failed");
                    System.out.println(error.getMessage());
                });

        Mono<McpSchema.CallToolResult> mono4 = asyncClient.callTool(request)
                .timeout(Duration.ofSeconds(30))
                .doOnSuccess(result -> {
                    System.out.println("--> get success response" + result);
                })
                .doOnError(error -> {
                    System.out.println("failed");
                    System.out.println(error.getMessage());
                });

        Thread.sleep(10000);

        threadPool.submit(() -> {
            mono1.subscribe();
        });

        threadPool.submit(() -> {
            mono2.subscribe();
        });

        threadPool.submit(() -> {
            mono3.subscribe();
        });

        threadPool.submit(() -> {
            mono4.subscribe();
        });